package com.wxh.bomb.netty.design.masterwoker.service;

import com.wxh.bomb.netty.design.masterwoker.core.Task;
import com.wxh.bomb.netty.design.masterwoker.core.Worker;

/**
 * 真正的任务处理者，只需要集成Worker并且实现handle方法
 *
 * @author wxh
 * @date：2017.10.10
 */
public class MyWorker extends Worker{

    @Override
    public Object handle(Task input) {
        Object output = null;
        try {
            // 表示处理task任务的耗时，可能是数据的加工，也可能是操作数据库...
            Thread.sleep(1000);
            System.out.println(input.getName() + "处理完...");
            output = input.getPrice();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return output;
    }
}
